package org.myfram.flink.flinkonjar.application;

import org.myfram.flink.flinkonjar.application.job.KafkaJoinHbaseJob;
import org.myfram.flink.flinkonjar.application.job.KafkaToHbaseInfoJob;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;


public class FlinkOnJarApplication {

    /*
        流作业启动类，不依托springboot
     */
    public static void main(String[] args) throws Exception {
        // new KafkaToHbaseInfoJob().execute(args, "KafkaToHbaseInfoJob");
        new KafkaJoinHbaseJob().execute(args, "KafkaJoinHbaseJob");
    }

}
